d05dc1a9e94f702089e847e1d30fc4cff505d4b3,hazelcast/src/main/java/com/hazelcast/queue/tx/TransactionalQueueProxySupport.java,TransactionalQueueProxySupport,pollInternal,#number#,71

Before Change


            Future<QueueItem> f = invocation.invoke();
            QueueItem item = f.get();
            if (item != null){
                if(!itemIdSet.add(item.getItemId())){
                    throw new TransactionException("Duplicate itemId: " + item.getItemId());
                }
                tx.addTransactionLog(new QueueTransactionLog(item.getItemId(), name, partitionId, new TxnPollOperation(name, item.getItemId())));

After Change


            Future<QueueItem> f = invocation.invoke();
            QueueItem item = f.get();
            if (item != null){
                if (reservedOffer != null && item.getItemId() == reservedOffer.getItemId()){
                    offerIdQueue.poll();
                    tx.removeTransactionLog(reservedOffer.getItemId());
                    return reservedOffer.getData();